package com.it.gmall.mq.entity;

import lombok.Data;
import org.springframework.amqp.rabbit.connection.CorrelationData;

// 此对象用来扩展CorrelationData对象的属性
@Data
public class GmallCorrelationData extends CorrelationData {

    //消息体
    private Object message;
    //交换机
    private String exchange;
    //路由键
    private String routingKey;
    //重试次数
    private int retryCount = 0;
    //是否延迟消息(死信)
    private boolean isDelay = false;
    //延迟时长(死信)
    private int delayTime = 10;
    //是否延迟消息(插件)
    private boolean isDelayMsg = false;
    //延迟时长(插件)
    private int delayTimeMsg = 10;
}
